<?php
/**
 * @Author: gan
 * @Description: MQ接口
 * @File:  MQInterface
 * @Version: 1.0.0
 * @Date: 2021/12/27 9:11 上午
 */

declare(strict_types=1);

namespace RX\Component\MQ\Impl;

interface MQInterface
{
    public function send(array $params);

    public function listen(array $params, callable $callback);

    public function init(array $params);

    public function close();
}
